package org.example.work1.order.rocketmq;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

public interface ConsumerService {

    /**
     * 消费帐户消息
     *
     * @param messages 消息
     * @return {@link ConsumeConcurrentlyStatus}
     */
    ConsumeConcurrentlyStatus consumeAccountMessage(List<MessageExt> messages);
}
